using System;
using System.Threading.Tasks;

namespace QQZiFramework.MQ
{
    public interface  IMQDriver
    {
        void Publish(string queueName, object obj);

        long GetLength(string queueName);

        void BindReceived(string queueName,Func<byte[], bool> fun);

        public void BindReceivedAsync(string queueName, Func<byte[], Task<bool>> fun);
    }
}
